namespace FServer.Core.Interfaces;

public interface IMessageQueueService
{
    Task PublishAsync<T>(T message, string? routingKey = null);
    Task SubscribeAsync<T>(string queueName, Func<T, Task> handler);
    Task StartAsync();
    Task StopAsync();
}
